package com.example.test_1_21.common;

import com.example.test_1_21.mqserver.core.BasicProperties;

import java.io.IOException;

//只是一个单纯的函数式接口（回调函数），收到消息之后要处理消息时调用的方法
@FunctionalInterface
public interface Consumer {
    //Delivery的意思是投递，这个方法预期是在每次服务器收到消息后来调用
    //通过这个方法把消息推送给对应的消费者
    void handleDelivery(String consumerTag, BasicProperties basicProperties,byte[] body) throws MQException, IOException;
}
